package com.jugheadzhou.core.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author jugheadzhou
 * @date 2021-09-28
 */
public interface CustomSink {
    /**
     * 自定义用于测试业务的输入通道进行通信
     */
    String INPUT = "test_input_channel";

    /**
     * 自定义输入管道
     */
    @Input(CustomSink.INPUT)
    SubscribableChannel input();
}
